<?php
namespace Home\Controller;

use Think\Controller;
use Common\Api\Test;
class IndexController extends Controller
{   

	public function index(){

$test = new Test();
echo $test->index();
    // $redis = new \Vendor\Redis\Redis();
    // // var_dump($redis->get('a'));
    // $res = M('pt_user')->limit('10000')->select();

    // $arr = array();
    //  // foreach($res as $key=>$val){

    // 	// $data = array();
    //  //   $data = $redis->hget('pt_user_id'.$val['zwcmopenid']);
    //  //  var_dump($data);
    //  //   $data[] = $val['id'];
    //  //  $redis->hset('pt_user_id'.$val['zwcmopenid'],$data);
    //  // 	$redis->hset('pt_user_info'.$val['id'],$val);
    //  // }
    //  foreach($res as $key=>$val){
       
    //       $zwid = $this->getZwid($val['zwcmopenid'],$val['telephone'],$val['id']);
    //      // var_dump($zwid);

    //      // //zwid和 zwcmopenid的关系
    //      $redis->set('zwcmopenid:'.$val['zwcmopenid'],$zwid);
    //      // echo "<br>";
    //  }
  }




  public function getZwid($zwcmopenid,$telephone,$pt_user_id){

    $redis = new \Vendor\Redis\Redis();
    if(!empty($zwcmopenid) || !empty($telephone)){

      $map = array();   //根据openid查
      $map['zwcmopenid'] = $zwcmopenid;
      $res = M('member')->where($map)->find();
      if($res){
         
         $zwid = $res['id'];
         $pt_user_id_list= explode(',',$pt_user_id);
         if(!in_array($pt_user_id,  $pt_user_id_list)){

              $pt_user_id_list[] = $pt_user_id;
              
              $res2 = M('member')->where('Id='.$res['id'])->save(array('pt_user_id'=>implode($pt_user_id_list,',')));
              //zwid  对应的pt_log_id
              $res['pt_user_id'] =implode($pt_user_id_list,',');
              $redis->hset("zwid:".$res['id'],$res);
         }
         
         return $zwid;
      }

      $map = array();    //根据电话号码查
      $map['telephone'] = $telephone;
      $res = M('member')->where($map)->find();
      if($res){
        
        $zwid = $res['id'];
        $pt_user_id_list= explode(',',$pt_user_id);
         if(!in_array($pt_user_id,  $pt_user_id_list)){

              $pt_user_id_list[] = $pt_user_id;
              
              $res2 = M('member')->where('Id='.$res['id'])->save(array('pt_user_id'=>implode($pt_user_id_list,',')));
              $res['pt_user_id'] =implode($pt_user_id_list,',');
              $redis->hset("zwid:".$res['id'],$res);
         }
         
         return $zwid;
      }

      $data['zwcmopenid'] = $zwcmopenid;
      $data['telephone'] = $telephone;
      $data['pt_user_id'] = implode(array($pt_user_id), ',');
      $res=  M('member')->add($data);
      $zwid = M('member')->getLastInsID();
      $redis->hset("zwid:".$zwid,$data);
      return $zwid;
    }
  }
}